package com.cntcdt.api.utils;

import java.util.List;

import com.cntcdt.api.db.dao.UpdateDeviceVersionDao;
import com.cntcdt.api.db.dao.UpdateLogDao;
import com.cntcdt.api.db.dao.UpdateTaskDao;
import com.cntcdt.api.db.model.UpdateDeviceVersionModel;
import com.cntcdt.api.db.model.UpdateLogModel;
import com.cntcdt.api.db.model.UpdateTaskModel;

public class UpdateTaskTimer implements Runnable {
	
	 public static boolean isRun = false;
		
	public static boolean isRun() {
		return isRun;
	}

	@Override
	public void run() {
		System.out.println("启动了========================================");
		isRun = true;
		while(true){
			List<UpdateTaskModel> updateTaskList = UpdateTaskDao.getInstance().find24HNotGetTask();
			for(UpdateTaskModel updateTask : updateTaskList){
				updateTask.setOpStatus(1);
				UpdateTaskDao.getInstance().update(updateTask);
				
				UpdateLogModel log = UpdateLogDao.getInstance().findBytaskId(updateTask.getId());
				if(log != null){
					log.setUpdateType(5);
					UpdateLogDao.getInstance().update(log);
				}
				
				UpdateDeviceVersionModel updateDeviceVersion = UpdateDeviceVersionDao.getInstance().findByPrimaryKey(updateTask.getVersionId());
				if(updateDeviceVersion != null){
					updateDeviceVersion.setUpdateType(5);
					UpdateDeviceVersionDao.getInstance().update(updateDeviceVersion);
				}
				
				System.out.println("处理任务========================================"+updateTask.getId());
			}
			try {
				Thread.sleep(60000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}
